上节研究了SparkStreaming与Kafka的关系,研究了08、10版本的不同的,研究了Producer、KafkaDStream,并且附带实例代码。在DStream初始化的时候,需要指定每个分区的Off...
浏览 76 次 标签: 大数据-103 Spark Streaming Kafka Offset管理详解 Scala自定义Offset